import java.net.*;

import java.util.*;

public class Receiver  {

   public static void main(String args[]) {

      int port = 5858;                               //组播的端口

      InetAddress group=null;                        //组播组的地址

      MulticastSocket socket=null;                   //多点广播套接字 

      try{

          group=InetAddress.getByName("239.255.8.0");//设置广播组的地址为239.255.8.0

          socket=new MulticastSocket(port);    //多点广播套接字将在port端口广播

          socket.joinGroup(group); //加入group

      }                          

      catch(Exception e){} 

      while(true) {   

         byte data[]=new byte[8192];

         DatagramPacket packet=null;

         packet=new DatagramPacket(data,data.length,group,port); //待接收的数据包

         try {  socket.receive(packet);

                String message=new String(packet.getData(),0,packet.getLength());

                System.out.println("接收的内容:\n"+message);

         }

         catch(Exception e) {}

      }

   }

}
